package test;

import org.apache.commons.io.monitor.FileAlterationMonitor;
import org.apache.commons.io.monitor.FileAlterationObserver;

import javax.servlet.http.HttpServlet;
import java.util.concurrent.TimeUnit;

public class RatingListener extends HttpServlet {

    public void init() {

        try {
            start();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    public void start() throws Exception {
        // 监控目录
        String rootDir = "F:\\spark\\result";
        // 轮询间隔 1 秒
        long interval = TimeUnit.SECONDS.toMillis(5);
        // 创建一个文件观察器用于处理文件的格式
        FileAlterationObserver observer = new FileAlterationObserver(rootDir);
        // 设置文件变化监听器
        observer.addListener(new FileListener());
        // 创建文件变化监听器
        FileAlterationMonitor monitor = new FileAlterationMonitor(interval, observer);

        // 开始监控
        monitor.start();
        System.out.println("开始监控-------------");
    }
}
